package com.lkx.kafka.monitor.dto;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

import java.util.List;

@Data
@NoArgsConstructor
@AllArgsConstructor
public class ConsumerGroupMetrics {
    private String groupId;
    private String topicName;
    private int consumerCount;
    private double consumeRate; // 消息/秒
    private long totalBacklog; // 总积压量
    private long maxDelayMs; // 最大延迟(ms)
    private String state; // 状态：稳定/再平衡/空
    private String coordinator; // 协调器节点
    private long currentOffset;  // 新增：当前位移
    private long endOffset;      // 新增：末端位移
}